package com.imooc.spark.kafka;

/**
 * Kafka Java
 */
public class FafkaClientApp {

    public static void main(String[] args) {

       // new KafkaProducer(KafkaProperties.TOPIC).start();


        /*
        会一直开启这个进程，监控kafka队列内容，有新内容就会输出到控制台
        但是不会从beginning开始。 从beginning开始可以自行设置。
         */
        new KafkaConsumer(KafkaProperties.TOPIC).start();
    }
}
